import random

import faker

from air_web.web_flask.dw import write_to_es

# structure = {
#     "cons_no": "",
#     "cons_name": "",
#     "data_date": "",
#     "on5": "",
#     "shi": "",
#     "on7": "",
#     "xian": "",
#     "type_code": "",
#     "type_code_sort": "",
#     "real_cons_no": "",
#     "mp_id": "",
#     "binary": "{'data_time': [~96], 'p_total': [~96], 'p_kt': [~96], 'p_base': [~96], 'p_std_left': [~96], 'p_std_right': [~96], 'is_day_max': [~96]}",
#
#     "max_data_time": "",
#     "max_p_total": "",
#     "max_p_kt": "",
#     "max_p_base": "",
#     "max_p_std_left": "",
#     "max_p_std_right": "",
# }

structure = {
    "cons_no": f"random.randint",
    "cons_name": "",
    "data_date": "",
    "on5": "",
    "shi": "",
    "on7": "",
    "xian": "",
    "type_code": "",
    "type_code_sort": "",
    "real_cons_no": "",
    "mp_id": "",
    "binary": "{'data_time': [~96], 'p_total': [~96], 'p_kt': [~96], 'p_base': [~96], 'p_std_left': [~96], 'p_std_right': [~96], 'is_day_max': [~96]}",
    "max_data_time": "",
    "max_p_total": "",
    "max_p_kt": "",
    "max_p_base": "",
    "max_p_std_left": "",
    "max_p_std_right": "",
}


es_idx = "powerload"

df = ""
df = df.astype({"data_time": "datetime64[ns]"})
